package com.sprouting.ops.service;


import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.sprouting.ops.dao.*;
import com.sprouting.ops.model.*;
import com.sprouting.ops.model.qo.AvailableDependQo;
import com.sprouting.ops.model.qo.OpsProductQo;
import com.sprouting.ops.model.vo.AvailableDependVo;
import com.sprouting.ops.model.vo.OpsProductVo;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;

/**
 * 产品(OpsProduct)() 表服务实现类
 *
 * @author ：lx（长沙麓谷）
 * @date 创建时间：2025-06-01 15:38:08
 */
@Service
@Slf4j
public class OpsProductService extends ServiceImpl<OpsProductDao, OpsProduct> {

    @Resource
    private OpsProductDao opsProductDao;
    @Resource
    private DromaraFileStorageDao dromaraFileStorageDao;
    @Resource
    private OpsProductDependDao opsProductDependDao;
    @Resource
    private OpsProductQuestionDao opsProductQuestionDao;
    @Resource
    private OpsCommonUseDao opsCommonUseDao;
    @Resource
    private OpsQuickAccessDao opsQuickAccessDao;


    /**
     * 分页查询 产品
     * @param page 分页参数
     * @param query 查询参数
     * @return
     */
    public Page<OpsProductVo> getListPage(Page page, OpsProductQo query){
        return opsProductDao.getListPage(page, query);
    }

    /**
     * 保存产品
     * @param bo 产品信息
     * @param opsUploadFile 图片文件
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveOpsProduct(OpsProduct bo, DromaraFileStorage opsUploadFile) {
        opsProductDao.insert(bo);
        if (opsUploadFile != null){
            dromaraFileStorageDao.updateById(opsUploadFile);
        }
    }

    /**
     * 更新产品
     * @param bo 产品信息
     * @param uploadFileArray 数组下标0， 新的  数组下标1 旧的文件
     */
    @Transactional(rollbackFor = Exception.class)
    public void updOpsProduct(OpsProduct bo, DromaraFileStorage[] uploadFileArray) {
        opsProductDao.updateById(bo);

        if (uploadFileArray[0] != null){
            // 新的
            dromaraFileStorageDao.updateById(uploadFileArray[0]);
        }
        if (uploadFileArray[1] != null){
            // 旧的文件
            dromaraFileStorageDao.updateById(uploadFileArray[1]);
        }
    }

    /**
     * 删除产品
     * @param product 产品
     * @param opsUploadFile 图片
     */
    @Transactional(rollbackFor = Exception.class)
    public void delOpsProduct(OpsProduct product, DromaraFileStorage opsUploadFile) {
        opsProductDao.deleteById(product);

        // 删除图片
        if (opsUploadFile != null){
            dromaraFileStorageDao.updateById(opsUploadFile);
        }

        // 删除依赖
        LambdaUpdateWrapper<OpsProductDepend> wrapper = new LambdaUpdateWrapper<>();
        wrapper.eq(OpsProductDepend::getProductId, product.getId());
        opsProductDependDao.delete(wrapper);

        // 常见问题
        LambdaUpdateWrapper<OpsProductQuestion> wrapperOpsProductQuestion = new LambdaUpdateWrapper<>();
        wrapperOpsProductQuestion.eq(OpsProductQuestion::getProductId, product.getId());
        opsProductQuestionDao.delete(wrapperOpsProductQuestion);

        // 常用文件和文件夹
        LambdaUpdateWrapper<OpsCommonUse> wrapperCommonUse = new LambdaUpdateWrapper<>();
        wrapperCommonUse.eq(OpsCommonUse::getBindId, product.getId());
        opsCommonUseDao.delete(wrapperCommonUse);

        // 删除环境? 不动，暂不这样级联处理

        // 删除快捷方式
        LambdaUpdateWrapper<OpsQuickAccess> wrapperQuickAccess = new LambdaUpdateWrapper<>();
        wrapperQuickAccess.eq(OpsQuickAccess::getBindId, product.getId());
        opsQuickAccessDao.delete(wrapperQuickAccess);
    }

    /**
     * 获取可选的依赖-产品
     * @param excludeList 排除的依赖id
     * @param query 查询参数
     * @return
     */
    public Page<AvailableDependVo> getAvailableDepend(Page page, List<String> excludeList, AvailableDependQo query) {
        return opsProductDao.getAvailableDepend(page, excludeList, query);
    }

    /**
     * 根据id查询产品
     * @param idList 主键
     * @return
     */
    public List<OpsProductVo> getByIdList(List<String> idList) {
        return opsProductDao.getByIdList(idList);
    }

    /**
     * 获取可添加的产品
     * @param userId 当前用户ID
     * @return
     */
    public List<OpsProduct> getByQuickProduct(String userId) {
        return opsProductDao.getByQuickProduct(userId);
    }

}
